package com.hailong.flink.nacos;

import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.config.ConfigService;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Properties;

/**
 * Created by 袁海龙 on 2020/2/26.
 * https://www.bilibili.com/video/av90742627
 */
public class FlinkNacosConfigTest {
    private static final Logger logger = LoggerFactory.getLogger(FlinkNacosConfig.class);

    public static void main(String[] args) throws Exception {
        String configValue = FlinkNacosConfig.getConfigValue("shuaige.wdw.swf");
        String chenjie = FlinkNacosConfig.getConfigValue("chenjie1");
        String ceshi = FlinkNacosConfig.getConfigValue("shuaige.ceshi");
        logger.info("configValue:{}",configValue);

    }
}
